LCOV - code coverage report
Current view: top level - src/ev - std_exec.c (source / functions) Hit Total Coverage
Test: Lely core libraries-2.4.0 Code Coverage Lines: 56 118 47.5 %
Date: 2024-05-21 10:56:08 Functions: 9 15 60.0 %
Legend: Lines: hit not hit | Branches: + taken - not taken # not executed Branches: 16 52 30.8 %

           Branch data     Line data    Source code
       1                 :            : /**@file
       2                 :            :  * This file is part of the event library; it contains the implementation of the
       3                 :            :  * standard executor functions.
       4                 :            :  *
       5                 :            :  * @see lely/ev/std_exec.h
       6                 :            :  *
       7                 :            :  * @copyright 2018-2019 Lely Industries N.V.
       8                 :            :  *
       9                 :            :  * @author J. S. Seldenthuis <jseldenthuis@lely.com>
      10                 :            :  *
      11                 :            :  * Licensed under the Apache License, Version 2.0 (the "License");
      12                 :            :  * you may not use this file except in compliance with the License.
      13                 :            :  * You may obtain a copy of the License at
      14                 :            :  *
      15                 :            :  *     http://www.apache.org/licenses/LICENSE-2.0
      16                 :            :  *
      17                 :            :  * Unless required by applicable law or agreed to in writing, software
      18                 :            :  * distributed under the License is distributed on an "AS IS" BASIS,
      19                 :            :  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
      20                 :            :  * See the License for the specific language governing permissions and
      21                 :            :  * limitations under the License.
      22                 :            :  */
      23                 :            : 
      24                 :            : #include "ev.h"
      25                 :            : 
      26                 :            : #if !LELY_NO_MALLOC
      27                 :            : 
      28                 :            : #include <lely/ev/exec.h>
      29                 :            : #include <lely/ev/std_exec.h>
      30                 :            : #include <lely/ev/task.h>
      31                 :            : #include <lely/util/errnum.h>
      32                 :            : #include <lely/util/util.h>
      33                 :            : 
      34                 :            : #include <assert.h>
      35                 :            : #include <stdint.h>
      36                 :            : #include <stdlib.h>
      37                 :            : 
      38                 :            : static void ev_std_exec_on_task_init(ev_exec_t *exec);
      39                 :            : static void ev_std_exec_on_task_fini(ev_exec_t *exec);
      40                 :            : static int ev_std_exec_dispatch(ev_exec_t *exec, struct ev_task *task);
      41                 :            : static void ev_std_exec_post(ev_exec_t *exec, struct ev_task *task);
      42                 :            : static void ev_std_exec_defer(ev_exec_t *exec, struct ev_task *task);
      43                 :            : static size_t ev_std_exec_abort(ev_exec_t *exec, struct ev_task *task);
      44                 :            : static void ev_std_exec_run(ev_exec_t *exec, struct ev_task *task);
      45                 :            : 
      46                 :            : // clang-format off
      47                 :            : static const struct ev_exec_vtbl ev_std_exec_vtbl = {
      48                 :            :         &ev_std_exec_on_task_init,
      49                 :            :         &ev_std_exec_on_task_fini,
      50                 :            :         &ev_std_exec_dispatch,
      51                 :            :         &ev_std_exec_post,
      52                 :            :         &ev_std_exec_defer,
      53                 :            :         &ev_std_exec_abort,
      54                 :            :         &ev_std_exec_run
      55                 :            : };
      56                 :            : // clang-format on
      57                 :            : 
      58                 :            : static inline struct ev_std_exec *ev_std_exec_from_exec(const ev_exec_t *exec);
      59                 :            : 
      60                 :            : struct ev_task_node {
      61                 :            :         struct ev_task_node *next;
      62                 :            :         struct sllist *queue;
      63                 :            : };
      64                 :            : 
      65                 :            : struct ev_exec_node {
      66                 :            :         struct ev_exec_node *next;
      67                 :            :         ev_exec_t *exec;
      68                 :            :         struct ev_task_node *queue;
      69                 :            : };
      70                 :            : 
      71                 :            : #if LELY_NO_THREADS
      72                 :            : static struct ev_exec_node *ev_exec_list;
      73                 :            : #else
      74                 :            : static _Thread_local struct ev_exec_node *ev_exec_list;
      75                 :            : #endif
      76                 :            : 
      77                 :            : static struct ev_exec_node **ev_exec_find(
      78                 :            :                 const ev_exec_t *exec, struct ev_exec_node **pnode);
      79                 :            : 
      80                 :            : void *
      81                 :          0 : ev_std_exec_alloc(void)
      82                 :            : {
      83                 :          0 :         struct ev_std_exec *exec = malloc(sizeof(*exec));
      84                 :            : #if !LELY_NO_ERRNO
      85         [ #  # ]:          0 :         if (!exec)
      86                 :          0 :                 set_errc(errno2c(errno));
      87                 :            : #endif
      88                 :            :         // cppcheck-suppress memleak symbolName=exec
      89         [ #  # ]:          0 :         return exec ? &exec->exec_vptr : NULL;
      90                 :            : }
      91                 :            : 
      92                 :            : void
      93                 :          0 : ev_std_exec_free(void *ptr)
      94                 :            : {
      95         [ #  # ]:          0 :         if (ptr)
      96                 :          0 :                 free(ev_std_exec_from_exec(ptr));
      97                 :          0 : }
      98                 :            : 
      99                 :            : ev_exec_t *
     100                 :          8 : ev_std_exec_init(ev_exec_t *exec_, ev_std_exec_impl_t *impl)
     101                 :            : {
     102                 :          8 :         struct ev_std_exec *exec = ev_std_exec_from_exec(exec_);
     103                 :            :         assert(impl);
     104                 :            : 
     105                 :          8 :         exec->exec_vptr = &ev_std_exec_vtbl;
     106                 :            : 
     107                 :          8 :         exec->impl = impl;
     108                 :            : 
     109                 :          8 :         return exec_;
     110                 :            : }
     111                 :            : 
     112                 :            : void
     113                 :          8 : ev_std_exec_fini(ev_exec_t *exec)
     114                 :            : {
     115                 :            :         (void)exec;
     116                 :          8 : }
     117                 :            : 
     118                 :            : ev_exec_t *
     119                 :          0 : ev_std_exec_create(ev_std_exec_impl_t *impl)
     120                 :            : {
     121                 :          0 :         int errc = 0;
     122                 :            : 
     123                 :          0 :         ev_exec_t *exec = ev_std_exec_alloc();
     124         [ #  # ]:          0 :         if (!exec) {
     125                 :          0 :                 errc = get_errc();
     126                 :          0 :                 goto error_alloc;
     127                 :            :         }
     128                 :            : 
     129                 :          0 :         ev_exec_t *tmp = ev_std_exec_init(exec, impl);
     130         [ #  # ]:          0 :         if (!tmp) {
     131                 :          0 :                 errc = get_errc();
     132                 :          0 :                 goto error_init;
     133                 :            :         }
     134                 :          0 :         exec = tmp;
     135                 :            : 
     136                 :          0 :         return exec;
     137                 :            : 
     138                 :          0 : error_init:
     139                 :          0 :         ev_std_exec_free((void *)exec);
     140                 :          0 : error_alloc:
     141                 :          0 :         set_errc(errc);
     142                 :          0 :         return NULL;
     143                 :            : }
     144                 :            : 
     145                 :            : void
     146                 :          0 : ev_std_exec_destroy(ev_exec_t *exec)
     147                 :            : {
     148         [ #  # ]:          0 :         if (exec) {
     149                 :          0 :                 ev_std_exec_fini(exec);
     150                 :          0 :                 ev_std_exec_free((void *)exec);
     151                 :            :         }
     152                 :          0 : }
     153                 :            : 
     154                 :            : static void
     155                 :       3484 : ev_std_exec_on_task_init(ev_exec_t *exec_)
     156                 :            : {
     157                 :       3484 :         struct ev_std_exec *exec = ev_std_exec_from_exec(exec_);
     158                 :            :         assert(exec->impl);
     159                 :            :         assert((*exec->impl)->on_task_init);
     160                 :            : 
     161                 :       3484 :         (*exec->impl)->on_task_init(exec->impl);
     162                 :       3484 : }
     163                 :            : 
     164                 :            : static void
     165                 :       3484 : ev_std_exec_on_task_fini(ev_exec_t *exec_)
     166                 :            : {
     167                 :       3484 :         struct ev_std_exec *exec = ev_std_exec_from_exec(exec_);
     168                 :            :         assert(exec->impl);
     169                 :            :         assert((*exec->impl)->on_task_fini);
     170                 :            : 
     171                 :       3484 :         (*exec->impl)->on_task_fini(exec->impl);
     172                 :       3484 : }
     173                 :            : 
     174                 :            : static int
     175                 :          0 : ev_std_exec_dispatch(ev_exec_t *exec, struct ev_task *task)
     176                 :            : {
     177                 :            :         assert(task);
     178                 :            :         assert(!task->exec || task->exec == exec);
     179                 :            : 
     180                 :          0 :         struct ev_exec_node **pnode = ev_exec_find(exec, &ev_exec_list);
     181         [ #  # ]:          0 :         if (!*pnode) {
     182                 :          0 :                 ev_std_exec_post(exec, task);
     183                 :          0 :                 return 0;
     184                 :            :         }
     185                 :            : 
     186         [ #  # ]:          0 :         if (!task->exec)
     187                 :          0 :                 task->exec = exec;
     188                 :            : 
     189         [ #  # ]:          0 :         if (task->func)
     190                 :          0 :                 task->func(task);
     191                 :            : 
     192                 :          0 :         return 1;
     193                 :            : }
     194                 :            : 
     195                 :            : static void
     196                 :   16782341 : ev_std_exec_post(ev_exec_t *exec_, struct ev_task *task)
     197                 :            : {
     198                 :   16782341 :         struct ev_std_exec *exec = ev_std_exec_from_exec(exec_);
     199                 :            :         assert(exec->impl);
     200                 :            :         assert((*exec->impl)->post);
     201                 :            :         assert(task);
     202                 :            :         assert(!task->exec || task->exec == exec_);
     203                 :            : 
     204         [ +  + ]:   16782341 :         if (!task->exec)
     205                 :          1 :                 task->exec = exec_;
     206                 :            : 
     207                 :   16782341 :         (*exec->impl)->post(exec->impl, task);
     208                 :   16782341 : }
     209                 :            : 
     210                 :            : static void
     211                 :          0 : ev_std_exec_defer(ev_exec_t *exec, struct ev_task *task)
     212                 :            : {
     213                 :            :         assert(exec);
     214                 :            :         assert(task);
     215                 :            :         assert(!task->exec || task->exec == exec);
     216                 :            : 
     217                 :          0 :         struct ev_exec_node **pnode = ev_exec_find(exec, &ev_exec_list);
     218         [ #  # ]:          0 :         if (!*pnode) {
     219                 :          0 :                 ev_std_exec_post(exec, task);
     220                 :          0 :                 return;
     221                 :            :         }
     222                 :            : 
     223         [ #  # ]:          0 :         if (!task->exec)
     224                 :          0 :                 task->exec = exec;
     225                 :            : 
     226                 :          0 :         ev_std_exec_on_task_init(exec);
     227                 :            :         assert((*pnode)->queue);
     228                 :            :         assert((*pnode)->queue->queue);
     229                 :          0 :         sllist_push_back((*pnode)->queue->queue, &task->_node);
     230                 :            : }
     231                 :            : 
     232                 :            : static size_t
     233                 :          1 : ev_std_exec_abort(ev_exec_t *exec_, struct ev_task *task)
     234                 :            : {
     235                 :          1 :         struct ev_std_exec *exec = ev_std_exec_from_exec(exec_);
     236                 :            :         assert(exec->impl);
     237                 :            :         assert((*exec->impl)->abort);
     238                 :            : 
     239                 :          1 :         size_t nnode = 0;
     240                 :          1 :         size_t nimpl = 0;
     241                 :            : 
     242                 :          1 :         struct ev_exec_node **pnode = ev_exec_find(exec_, &ev_exec_list);
     243         [ +  - ]:          1 :         if (*pnode) {
     244                 :            :                 assert((*pnode)->queue);
     245                 :          1 :                 struct sllist *queue = (*pnode)->queue->queue;
     246                 :            :                 assert(queue);
     247         [ -  + ]:          1 :                 if (!task) {
     248         [ #  # ]:          0 :                         while (sllist_pop_front(queue)) {
     249                 :          0 :                                 ev_std_exec_on_task_fini(exec_);
     250                 :          0 :                                 nnode += nnode < SIZE_MAX;
     251                 :            :                         }
     252         [ -  + ]:          1 :                 } else if (sllist_remove(queue, &task->_node)) {
     253                 :          0 :                         ev_std_exec_on_task_fini(exec_);
     254                 :          0 :                         nnode++;
     255                 :            :                 }
     256                 :            :         }
     257                 :            : 
     258   [ +  -  +  - ]:          1 :         if (!task || !nnode)
     259                 :          1 :                 nimpl = (*exec->impl)->abort(exec->impl, task);
     260                 :            : 
     261         [ +  - ]:          1 :         return nimpl < SIZE_MAX - nnode ? nnode + nimpl : SIZE_MAX;
     262                 :            : }
     263                 :            : 
     264                 :            : static void
     265                 :   16782340 : ev_std_exec_run(ev_exec_t *exec_, struct ev_task *task)
     266                 :            : {
     267                 :   16782340 :         struct ev_std_exec *exec = ev_std_exec_from_exec(exec_);
     268                 :            :         assert(exec->impl);
     269                 :            :         assert((*exec->impl)->post);
     270                 :            :         assert(task);
     271                 :            :         assert(!task->exec || task->exec == exec_);
     272                 :            : 
     273         [ -  + ]:   16782340 :         if (!task->exec)
     274                 :          0 :                 task->exec = exec_;
     275                 :            : 
     276         [ +  - ]:   16782340 :         if (task->func) {
     277                 :   16782340 :                 struct ev_exec_node **plist = &ev_exec_list;
     278                 :            : 
     279                 :            :                 struct sllist queue;
     280                 :   16782340 :                 sllist_init(&queue);
     281                 :   16782340 :                 struct ev_task_node queue_node = { NULL, &queue };
     282                 :   16782340 :                 struct ev_exec_node exec_node = { NULL, exec_, &queue_node };
     283                 :            : 
     284                 :   16782340 :                 struct ev_exec_node **pnode = ev_exec_find(exec_, plist);
     285         [ -  + ]:   16782340 :                 if (*pnode) {
     286                 :          0 :                         queue_node.next = (*pnode)->queue;
     287                 :          0 :                         (*pnode)->queue = &queue_node;
     288                 :            :                 } else {
     289                 :   16782340 :                         exec_node.next = *plist;
     290                 :   16782340 :                         *plist = &exec_node;
     291                 :            :                 }
     292                 :            : 
     293                 :   16782340 :                 task->func(task);
     294                 :            : 
     295                 :   16782340 :                 pnode = ev_exec_find(exec_, plist);
     296                 :            :                 assert(*pnode);
     297                 :            :                 assert((*pnode)->queue == &queue_node);
     298         [ -  + ]:   16782340 :                 if ((*pnode)->queue->next) {
     299                 :          0 :                         (*pnode)->queue = (*pnode)->queue->next;
     300                 :            :                 } else {
     301                 :   16782340 :                         *pnode = (*pnode)->next;
     302                 :            :                 }
     303                 :            : 
     304         [ -  + ]:   16782340 :                 while ((task = ev_task_from_node(sllist_pop_front(&queue)))) {
     305                 :            :                         assert(task->exec == exec_);
     306                 :          0 :                         (*exec->impl)->post(exec->impl, task);
     307                 :          0 :                         ev_std_exec_on_task_fini(exec_);
     308                 :            :                 }
     309                 :            :         }
     310                 :   16782340 : }
     311                 :            : 
     312                 :            : static inline struct ev_std_exec *
     313                 :   33571658 : ev_std_exec_from_exec(const ev_exec_t *exec)
     314                 :            : {
     315                 :            :         assert(exec);
     316                 :            : 
     317                 :   33571658 :         return structof(exec, struct ev_std_exec, exec_vptr);
     318                 :            : }
     319                 :            : 
     320                 :            : static struct ev_exec_node **
     321                 :   33564681 : ev_exec_find(const ev_exec_t *exec, struct ev_exec_node **pnode)
     322                 :            : {
     323   [ +  +  -  + ]:   33564681 :         while (*pnode && (*pnode)->exec != exec)
     324                 :          0 :                 pnode = &(*pnode)->next;
     325                 :   33564681 :         return pnode;
     326                 :            : }
     327                 :            : 
     328                 :            : #endif // !LELY_NO_MALLOC

Generated by: LCOV version 1.14